# -*- coding: utf-8 -*-
from datetime import timedelta

from airflow.providers.apache.hdfs.sensors.web_hdfs import WebHdfsSensor

jms_dwd__dwd_yl_oms_oms_order_hf = WebHdfsSensor(
    pool='unlimited_pool',
    task_id="jms_dwd__dwd_yl_oms_oms_order_hf",
    filepath='/dw/hive/jms_dwd.db/external/dwd_yl_oms_oms_order_hf/dt={{ execution_date | hour_add(-1) | cst_hour }}',
    execution_timeout=timedelta(minutes=60),
    #邮箱更换
    email=['rongguangfan@jtexpress.com', 'yl_bigdata@yl-scm.com'],
    retries=2,
)
